package cocurrency.queue;

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.PriorityBlockingQueue;

/**
 * Created by luzl on 4/6/2017.
 */
public class Main {

    public static void main(String[] args){
        //LinkedBlockingQueue<String> queue=new LinkedBlockingQueue<>();
        PriorityBlockingQueue queue=new PriorityBlockingQueue();
        Producer producer=new Producer(queue);
        Consumer consumer=new Consumer(queue);
        producer.start();
        consumer.start();
    }
}
